package cn.jly.boot.kafka.service;

/**
 * @PackageName cn.jly.boot.kafka.service
 * @ClassName KafkaProducer
 * @Description kafka生产者
 * @Author 姬岚洋
 * @Date 2021/1/10 下午 9:20
 */
public interface KafkaProducer {
    /**
     * 简单生产者
     *
     * @param topic   主题
     * @param message 消息
     */
    void sendMessage(String topic, String message);

    /**
     * 携带回调的生产者
     *
     * @param topic   主题
     * @param message 消息
     */
    void sendMessageWithCallback(String topic, String message);
}
